package com.jthinking.service.kafka.delay.queue;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * 精度：秒
 * 使用方式：
 * 往 kafka-delay-queue-xxxxxxxx 发送消息，指定key为延迟时间
 * 会在到达延迟时间后，在 kafka-delay-queue-xxxxxxxx-timeout 接收到消息
 * 消息的长度有限制，
 * 最小文件的存储块单位为分钟：存储结构：第几秒(0-59)值长度(1-xxx)值(xxxx)
 */
@SpringBootApplication
public class KafkaDelayQueueApplication {

	public static void main(String[] args) {
		SpringApplication.run(KafkaDelayQueueApplication.class, args);
	}

}
